package cn.zqh.auth.config;

import org.springframework.amqp.core.FanoutExchange;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @Author: zqh
 * @Date: 2023-03-11-11:58
 * @Description: 声明消费者$
 */
@Configuration
public class MyRabbitMq {

    private static String EXCHANGE_NAME = "ms1";


    /**
     * @Author: zqh
     * @Date:
     * @Description: 上面交换机
     */
    @Bean
    public FanoutExchange exchange(){
        return new FanoutExchange(EXCHANGE_NAME,true,false);
    }

}
